# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash import BashOperator
from jms.dwd.tab.dwd_dependent_hi.dwd_wide_yl_rt_ssmx_bill_detail_hf_07 import jms_dwd__dwd_wide_yl_rt_ssmx_bill_detail_hf_07
from jms.dwd.tab.dwd_dependent_hi.dwd_tab_barscan_taking_base_hi_07 import jms_dwd__dwd_tab_barscan_taking_base_hi_07
from jms.dwd.tab.dwd_dependent_hi.dwd_tab_barscan_warehousing_base_hi_07 import jms_dwd__dwd_tab_barscan_warehousing_base_hi_07
from jms.dwd.tab.dwd_dependent_hi.dwd_tab_barscan_send_base_hi_07 import jms_dwd__dwd_tab_barscan_send_base_hi_07
from jms.dwd.tab.dwd_dependent_hi.dwd_tab_barscan_arrival_base_hi_07 import jms_dwd__dwd_tab_barscan_arrival_base_hi_07
from jms.dwd.tab.dwd_dependent_hi.dwd_tab_barscan_collect_base_hi_07 import jms_dwd__dwd_tab_barscan_collect_base_hi_07
from jms.dwd.tab.dwd_dependent_hi.dwd_tab_barscan_deliver_base_hi_07 import jms_dwd__dwd_tab_barscan_deliver_base_hi_07

oss_dm_no_operate_summary_dt = BashOperator(
    task_id='oss_dm_no_operate_summary_dt',
    email=['wangmenglei@jtexpress.com','yl_bigdata@yl-scm.com'],
    pool='unlimited_pool',
    bash_command='jms/oss/dm_no_operate_summary_dt/execute.sh',
    execution_timeout=timedelta(minutes=50),
    sla=timedelta(hours=7)
)

oss_dm_no_operate_summary_dt << [
    jms_dwd__dwd_wide_yl_rt_ssmx_bill_detail_hf_07 ,
    jms_dwd__dwd_tab_barscan_taking_base_hi_07,
    jms_dwd__dwd_tab_barscan_warehousing_base_hi_07,
    jms_dwd__dwd_tab_barscan_send_base_hi_07,
    jms_dwd__dwd_tab_barscan_arrival_base_hi_07,
    jms_dwd__dwd_tab_barscan_collect_base_hi_07,
    jms_dwd__dwd_tab_barscan_deliver_base_hi_07
]
